#ifndef KAFKA_THREAD_H
#define KAFKA_THREAD_H

#include "game_thread.h"
typedef int (*kafka_msg_callback)(struct rd_kafka_message_s *rkm);
pthread_t create_kafka_send_thread(char *brokers, void *param);
pthread_t create_kafka_recv_thread(char *brokers, char *groupid, int partid, char *topic,
	kafka_msg_callback callback, void *param);

int wakeup_send_thread(int force);
int send_msg(void *data, int len, char *topic, int partid);

#endif /* KAFKA_THREAD_H */
